﻿using MySqlSync.Core.Models;

namespace MySqlSync.Core.Interfaces
{
    /// <summary>
    /// Kafka消费者服务接口
    /// </summary>
    public interface IKafkaConsumerService : IAsyncDisposable
    {
        /// <summary>
        /// 消费消息
        /// </summary>
        Task ConsumeAsync(Func<SyncRecord, Task> handleMessage, CancellationToken cancellationToken);

    }
}
